package com.ideal.lx_mss.mapper;



import com.ideal.lx_mss.common.entity.KafkaTableEntity;
import com.ideal.lx_mss.common.entity.KafkaTopicEntity;
import com.ideal.lx_mss.common.entity.MssKafkaEntity;
import org.apache.ibatis.annotations.Mapper;

import java.util.ArrayList;
import java.util.List;

/**
 * 
 * 
 * @author wangxiang1998
 * @email 2293672863@qq.com
 * @date 2023-12-20 10:32:04
 */
@Mapper
public interface KafkaTopicMapper {


    int addKafkaData(MssKafkaEntity kafkaEntity);

    void saveKafkaBatch(ArrayList<MssKafkaEntity> dataEntities);

    List<KafkaTopicEntity> getKafkaTopicList();

    List<MssKafkaEntity> selectKafkaList(MssKafkaEntity mssKafkaEntity);


}
